package com.zhao.task.inter;

/**
 * 消费者接口
 *
 * @author zhao
 * @date 2018-11-04
 */
public interface Consume<T> {

    /**
     * 消费
     *
     * @param t 消费对象
     * @return
    */
    void consume(T t);

    /**
     * 消费成功回调函数
     *
     * @param t 消费对象
     * @return
    */
    void consumeSuccess(T t);

    /**
     * 消费失败回调函数
     *
     * @param t 消费对象
     * @return
    */
    void consumeFail(T t);
}
